DROP TABLE IF EXISTS jms_dm.dm_collect_duration_dt;
CREATE EXTERNAL TABLE jms_dm.dm_collect_duration_dt (
    taking_time_period            STRING COMMENT '揽收时间段',
    waybill_cnt                   BIGINT COMMENT '票数',
    subordinate_agent_name        STRING COMMENT '揽收点代理区名称',
    subordinate_agent_code        STRING COMMENT '揽收点代理区编码',
    taking_network_name           STRING COMMENT '网点名称',
    taking_network_code           STRING COMMENT '网点编号',
    entrepot_network_name         STRING COMMENT '集散名称',
    entrepot_network_code         STRING COMMENT '集散编号',
    center_network_name           STRING COMMENT '中心名称',
    center_network_code           STRING COMMENT '中心编号',
    sum_taking_entrepot_dur       DECIMAL(18, 5) COMMENT '网点-集散时长总和：集散的最早扫描时间-寄件网点最早扫描时间',
    sum_entrepot_arrival_send_dur DECIMAL(18, 5) COMMENT '集散到-发时长总和：集散的最晚扫描时间-集散最早扫描时间',
    sum_entrepot_center_dur       DECIMAL(18, 5) COMMENT '集散-中心时长总和：中心最早扫描时间-集散最早扫描时间',
    sum_taking_center_dur         DECIMAL(18, 5) COMMENT '网点-中心时长总和：中心最早扫描时间-寄件网点最早扫描时间',
    sum_taking_entrepot_trans_dur DECIMAL(18, 5) COMMENT '网点-集散运输时长总和：集散最早扫描时间-寄件网点最晚扫描时间',
    sum_entrepot_center_trans_dur DECIMAL(18, 5) COMMENT '集散-首中心运输时长总和：中心最早扫描时间-集散最晚扫描时间',
    sum_taking_center_trans_dur   DECIMAL(18, 5) COMMENT '网点-首中心运输时长总和：中心最早扫描时间-寄件网点最晚扫描时间'
)
COMMENT '始发出港时长，T+2，每天上传到 oss://jt-report/始发出港时长/'
PARTITIONED BY (dt STRING COMMENT '揽收日期')
STORED AS PARQUET
LOCATION '/dw/hive/jms_dm.db/external/dm_collect_duration_dt'
TBLPROPERTIES (
    'discover.partitions' = 'false',
    'parquet.column.index.access' = 'true'
    );
MSCK REPAIR TABLE jms_dm.dm_collect_duration_dt;
